<?php

namespace app\common\job;

use app\common\model\Trade;
use think\queue\Job;

/**
 * 订单完成
 * Class TradeEnd
 * @package app\common\job
 */
class TradeEnd
{
    /**
     * fire是消息队列默认调用的方法
     * @param Job $job 当前的任务对象
     * @param array|mixed $data 发布任务时自定义的数据
     */
    public function fire(Job $job, $data)
    {
        $id = $data['id'] ?? null;

        $trade = Trade::where('id', $id)->find();

        // 触发订单完成事件
        if ($trade) {
            event('TradeEnded', $trade);
        }

        $job->delete();
    }

}
